package operator.function;

import io.reactivex.Observable;
import util.RxJavaHelper;

class RepeatOperator {

    public static void main(String[] args) {
        repeat();
    }

    /**
     * 按指定次数重复发送
     */
    static void repeat(){
        Observable.just(1,2,3,4)
                .repeat(2)
                .subscribe(RxJavaHelper.getConsumer());
    }


}
